ed8babb97408a8af3ed3aa38985da00f86ce0065,core/src/main/java/org/elasticsoftware/elasticactors/cluster/LocalActorShard.java,LocalActorShard,undeliverableMessage,#InternalMessage#,124
Before Change
@Override
public void undeliverableMessage(InternalMessage message) throws Exception {
// get the durable flag
Message messageAnnotation = Class.forName(message.getPayloadClass()).getAnnotation(Message.class);
final boolean durable = (messageAnnotation != null) && messageAnnotation.durable();
// input is the message that cannot be delivered
InternalMessage undeliverableMessage;
if (message instanceof InternalMessageImpl) {
undeliverableMessage = new InternalMessageImpl( message.getReceiver(),
message.getSender(),
message.getPayload(),
message.getPayloadClass(),
After Change
message.getSender(),
message.getPayload(),
message.getPayloadClass(),
message.isDurable(),
true);
}
messageQueue.offer(undeliverableMessage);